package org.way.rocketMq.service;

/**
 * topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
 * selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
 * 此方法加了tag做区分，上面没有添加tag做区分时，不能共存
 * 不然生产者发送一条消息，这两个都会去消费，如果类型不同会有一个报错，所以实际运用中最好加上tag
 */
//@Slf4j
//@Component
//@RocketMQMessageListener(topic = MqConstant.topic, selectorExpression = MqConstant.tag, consumerGroup = MqConstant.consumerGroup)
//public class MqConsumerTagService implements RocketMQListener<MessageDto> {
//
//    @Override
//    public void onMessage(MessageDto messageDto) {
//        log.info("监听到消息：{}", JSONUtil.toJsonStr(messageDto));
//    }
//
//}
